package com.imooc.ecommerce.stream.qinyi;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * <p>自定义输入信道
 *
 * @author Yaxi.Zhang
 * @since 2022/11/15 20:07
 */
public interface QinyiSink {

    String INPUT = "qinyiInput";

    /**
     * 输入信道的名称是 qinyiInput, 需要使用 Stream 绑定器在 yml 文件中配置
     */
    @Input(QinyiSink.INPUT)
    SubscribableChannel qinyiInput();

}

